//package org.lwd.datalink.domain.plugin.writer.obs;
//
//import com.google.common.collect.Sets;
//import lombok.Getter;
//import lombok.Setter;
//import org.lwd.datalink.domain.media.MediaSourceType;
//import org.lwd.datalink.domain.plugin.PluginWriterParameter;
//import org.lwd.datalink.domain.plugin.writer.hdfs.CommitMode;
//
//import java.util.Set;
//
///**
// * @Author: weidong.lin
// * @Description: obs
// */
//@Setter
//@Getter
//public class ObsWriterParameter extends PluginWriterParameter {
//    private CommitMode commitMode = CommitMode.Hflush;// Hflush, Hsync
//    private Integer streamLeisureLimit = 600000;// 单位：毫秒
//    private Integer obsPacketSize = 20971520;// 20*1024*1024,packet-size设置为20M，保证数据一次性发送到hdfs-server端，避免被截断
//    private Long hsyncInterval = 30000L;//单位：毫秒，用于控制当CommitMode为Hflush的时候，多长时间进行一次hsync操作
//    private String hbasePath = "user/hbase";
//    private String mysqlBinlogPath = "user/mysql/binlog";
//    private Integer socketTimeout = 180000;//默认是60000，设置大点，防止流量高峰hdfs响应慢连接超时
//
//    @Override
//    public String initPluginName() {
//        return "writer-obs";
//    }
//
//    @Override
//    public String initPluginClass() {
//        return "org.lwd.datalink.writer.obs.ObsTaskWriter";
//    }
//
//    @Override
//    public String initPluginListenerClass() {
//        return "org.lwd.datalink.writer.obs.ObsTaskWriterListener";
//    }
//
//    @Override
//    public Set<MediaSourceType> initSupportedSourceTypes() {
//        return Sets.newHashSet(MediaSourceType.OBS);
//    }
//}
